package com.example.springcloudstreamrabbitmq;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

/**
 * @author Harry
 * @date 2018/4/4 17:21
 */
public interface StreamWasConfig {

    String INPUT_WAS = "inputWas";
    String OUTPUT_WAS = "outputWas";

    @Input(INPUT_WAS)
    SubscribableChannel inputOrder();

    @Output(OUTPUT_WAS)
    MessageChannel outputOrder();

}
